// ws 
const WebSocket = require('ws')
const { WebSocketServer } = require('ws')

const wss = new WebSocketServer({ port: 8080 });

wss.on('connection', function connection(ws) {
    ws.on('error', console.error);

    ws.on('message', function message(data, isBinary) {
        wss.clients.forEach(function each(client) {
            // 把自己搬掉  client !== ws &&  这个是广播消息
            if (client.readyState === WebSocket.OPEN) {
                client.send(data, { binary: isBinary });
            }
        });
    });
});



// // 创建 WebSocket 连接  客户端写法
// const ws = new WebSocket('ws://localhost:8080');
// ws.onopen = ()=>{console.log('连接成功')}
// ws.onmessage = (mesObj)=>{console.log(mesObj)}
// ws.onerror = (err)=>{console.log(err)}
// // 连接成功时触发
// ws.addEventListener('open', event => {
//     console.log('WebSocket 连接已经建立');
// });

// // 接收服务端发送的消息时触发
// ws.addEventListener('message', event => {
//     console.log(`接收到消息：${event.data}`);
// });

// // 发送消息给服务端
// ws.send('Hello, WebSocket!');